package cn.fz.rocketmqdemo01.service;

import org.apache.rocketmq.remoting.protocol.route.BrokerData;

import java.util.List;

public interface RocketAdminService {
    List<String> getClusterNameList(String serverAddress);

    List<String> getTopicList(String serverAddress);

    List<BrokerData> getBrokerDataList(String serverAddress);

    void createTopic(String serverAddress, String topicName);

    void deleteTopic(String serverAddress, String topicName);
}
